package com.dddframework.mq.core;

public abstract class MQEventStorer {

    /**
     * 消息持久化
     */
    public abstract <T> void store(String topic, T msg);
}